package com.example.jacksen.alldemo.Rxbus.Rxjava;

import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;

import com.example.jacksen.alldemo.R;

import java.util.concurrent.TimeUnit;

import rx.Observable;

public class RxjavaDemo extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_rxjava_demo);
    }
    /**
     * 调用Create方法
     */
    public void crateMethod(View view){
        RxUtils.createObserable();

    }
    /**
     * 调用Create1方法
     */
    public void crateMethod1(View view){
        RxUtils.createPrint();
    }

    /**
     * from方法
     * @param view
     */
    public void from(View view){
        RxUtils.from();
    }
    /**
     * interval方法
     * @param view
     */
    public void interval(View view){
        RxUtils.interval();
    }
    /**
     * 处理数组的集合
     * @param view
     */
    public void just(View view){
        RxUtils.just();
    }
    /**
     *过滤
     * @param view
     */
    public void filter(View view){
        RxUtils.filter();
    }
    /**
     *范围
     * @param view
     */
    public void range(View view){
        RxUtils.range();
    }


}
